//
// Decompiled by Jadx - 331ms
//
package ea;

import en.c;

public abstract class a<T> extends c<T> {
    public abstract void b(T t);

    public abstract void f(dw.a aVar);

    public void k() {
    }

    public void onComplete() {
    }

    public final void onError(Throwable th) {
        dw.a handleException;
        try {
            if (th instanceof dw.a) {
                th.getMessage();
                handleException = (dw.a) th;
            } else {
                th.getMessage();
                handleException = dw.a.handleException(th);
            }
            f(handleException);
        } catch (Throwable unused) {
            th.printStackTrace();
        }
    }

    public final void onNext(T t) {
        try {
            b(t);
        } catch (Throwable th) {
            th.printStackTrace();
            onError(th);
        }
    }
}
